package com.hanxun.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

/**
 * 1.在hello world模型上的升级，不需要交换机绑定，可以有多个消费者消费消息默认情况下，
 * 消息的分发平均分配到每个不同的消费者上* 可以进行“能者多劳”的设置，
 * 即：那个消费者线程处理的快，就可在获得同一队列更多的消息进行处理
 * 配置work模式 config类，项目运行自动创建队列queue
 * @Author: zzq
 * @Data:2024-02-06 1:36
 */
@Component
public class WorkExchangeQueueConfig {
    public final static String TEST_WORK_QUEUE="TEST_WORK_QUEUE";

    /**
     * work queue 模型
     */
    @Bean
    Queue workQueue(){
        return new Queue(TEST_WORK_QUEUE);
    }

};
